package com.kly.user.task.traffic.v2;

import cn.hutool.core.net.NetUtil;
import com.alibaba.nacos.api.config.annotation.NacosValue;
import com.fqgj.log.factory.LogFactory;
import com.fqgj.log.interfaces.Log;
import com.kly.user.db.dao.*;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class IssueUserPondTaskV2 {

    private static Log logger = LogFactory.getLog(IssueUserPondTaskV2.class);

    @Resource
    private UserDao userDao;

    @Resource
    private ChatterFactorDao chatterFactorDao;

    @Resource
    private ChatterLevelDao chatterLevelDao;

    @Resource
    private ChatterWorkSettingDao chatterWorkSettingDao;

    @Resource
    private UserWlmDao userWlmDao;

    @Resource
    private UserChatterMappingDao userChatterMappingDao;

    @Resource
    private IssueUserPoolDao issueUserPoolDao;

    @Resource
    private UserHomePageRecordDao userHomePageRecordDao;

    @NacosValue(value = "${task.traffic.score.executor.ip}", autoRefreshed = true)
    private String trafficScoreJobIp;

    private String localIP = NetUtil.getLocalhostStr();


    //    @Scheduled(fixedDelay = 150000)
    public void execute() {
        logger.info("=============流量分值计算任务V2, 开始");
        if (!trafficScoreJobIp.contains(localIP)) {
            logger.info("=============流量分值计算任务V2, currentLocalAddress:{}, onlyExecuteTaskIn:{}", localIP, trafficScoreJobIp);
            return;
        }




    }


}
